package com.boot2.core.mqtt;

/**
* @author zhangweilin
* @date 2018/7/4 17:30 
* @description:  定时任务路由分发器
*/
public abstract class MqttMessageRouter {

//    @Autowired
//    MqttMessageUpService mqttMessageUpService;
    /**
     * 各@PostConstruct之间顺序不好控制，故此处还是手动调用
     */
    public void init()
    {
//        map.put(MqttMessageTypeEnum.UP.updateTime.name(), mqttMessageUpService::updateTime);
//        map.put(MqttMessageTypeEnum.UP.serverOpenedSuccess.name(), mqttMessageUpService::updateServerOpenedSuccess);
//        map.put(MqttMessageTypeEnum.UP.closedSuccess.name(), mqttMessageUpService::updateClosedSuccess);
//        map.put(MqttMessageTypeEnum.UP.alreadyOpened.name(), mqttMessageUpService::updateAlreadyOpened);
//        map.put(MqttMessageTypeEnum.UP.serverOpenedError.name(), mqttMessageUpService::updateServerOpenedError);
//        map.put(MqttMessageTypeEnum.UP.updateOpen.name(), mqttMessageUpService::updateOpen);
//        map.put(MqttMessageTypeEnum.UP.updateClose.name(), mqttMessageUpService::updateClose);
//        map.put(MqttMessageTypeEnum.UP.emergencyOpenedSuccess.name(), mqttMessageUpService::updateEmergencyOpenedSuccess);
//        map.put(MqttMessageTypeEnum.UP.warning.name(), mqttMessageUpService::updateWarning);
//        map.put(MqttMessageTypeEnum.UP.humiture.name(), mqttMessageUpService::updateHumiture);
    }
}
